package com.didispace;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface MySink {

    String INPUT_1 = "Output-1";    // 该名称需要与定义 MessageChannel 的 @Output 中的 value 参数一致

    String INPUT_2 = "Output-2";

    @Input(MySink.INPUT_1)
    SubscribableChannel input1();

    @Input(MySink.INPUT_2)
    SubscribableChannel input2();
}
